package com.ytktt.study.week12.task4.api;

import com.ytktt.study.week12.task4.Order;
import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.support.Acknowledgment;

/**
 * 消费者业务逻辑抽象
 *
 * @author ytk
 */
public interface ConsumerService {

    void consumer(ConsumerRecord<String, Order> consumerRecord, Acknowledgment ack, Consumer consumer);
}
